package feat1;

import reactor.core.publisher.Flux;

public class ReactorExample {
    public static void main(String[] args) {
        Flux.just("Hello", "Reactive", "World")
                .subscribe(
                        item -> System.out.println("Received: " + item),
                        error -> System.err.println("Error: " + error),
                        () -> System.out.println("Completed")
                );
    }
}